package day1;

import org.springframework.dao.DataAccessException;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.data.redis.core.RedisTemplate;

import javax.annotation.Resource;

public class Redis4Demo {

    @Resource
    RedisTemplate redisTemplate;

    /**
     * 在单节点中管道的使用。
     */
    void test1(){
        //使用redisTemplate创建一个管道。
        redisTemplate.executePipelined(new RedisCallback<Object>() {
            @Override
            public Object doInRedis(RedisConnection redisConnection) throws DataAccessException {
                for (int i = 0; i < 10; i++) {
                    //这就是管道里面了，只需要在这里写命令即可。
                    redisConnection.set(("key_"+i).getBytes(),("value_"+i).getBytes());
                }
                return null;
            }
        });
    }
}
